 package srdb.migration.schema.metadata;
 
 import java.io.PipedInputStream;
 import java.io.PipedOutputStream;
 
 public class LargeBufferInputStream extends PipedInputStream
 {
   private int numRows;
 
   public LargeBufferInputStream(int bufferSize)
   {
     this.buffer = new byte[bufferSize];
     this.numRows = 0;
   }
 
   public LargeBufferInputStream(PipedOutputStream out, int bufferSize)
   {
     this.buffer = new byte[bufferSize];
     this.numRows = 0;
   }
 
   public int getLength() {
     return this.in + 1;
   }
 
   public int getNumRows() {
     return this.numRows;
   }
 
   public void addRowNum() {
     this.numRows += 1;
   }
 }

/* 

 * 
 */